// 此文件实现socket ... 单例模式
export default class SocketService {
  // 单例模式
  static instance = null
  static get Instance () {
    if (!this.instance) {
      this.instance = new SocketService()
    }
    return this.instance
  }

  // 和服务端连接的实例对象
  ws = null

  // 存储回调函数
  callBackMapping = {}

  // 标识是否连接成功
  connected = false
  // 记录重连次数
  sendRetryCoundt = 0
  // 重新连接尝试的次数
  connectRetryCount = 0

  // 连接服务器的方法
  connect () {
    // 连接服务器
    if (!window.WebSocket) {
      return alert('您的浏览器暂不支持WebSocket')
    }
    this.ws = new WebSocket('ws://39.99.159.195:8083') // 后端websocket端口
    // 连接成功的事件
    this.ws.onopen = () => {
      this.connected = true
      this.connectRetryCount = 0
      console.log('服务端连接成功！')
    }
    // 连接失败的事件
    this.ws.onclose = () => {
      this.connected = false
      this.connectRetryCount++
      console.log('服务端连接失败！')
      setTimeout(() => {
        this.connect()
      }, this.connectRetryCount * 500)
    }
    // 得到服务端发送数据
    this.ws.onmessage = msg => {
      // console.log('从服务端获取到的数据：', msg)
      const recvData = JSON.parse(msg.data)
      const { action, socketType } = recvData
      // console.log(chartName, value)
      // 判断回调函数是否存在
      if (this.callBackMapping[socketType]) {
        if (action === 'getData') {
          const realData = JSON.parse(recvData.data)
          this.callBackMapping[socketType].call(this, realData) // 调用对应数据的处理函数
        } else if (action === 'fullScreen') {
          this.callBackMapping[socketType].call(this, recvData) // 调用对应数据的处理函数
        } else if (action === 'themeChange') {
          this.callBackMapping[socketType].call(this, recvData) // 调用对应数据的处理函数
        }
      }
    }
  }

  // 注册回调函数
  registerCallBack (socketType, callBack) {
    // console.log('注册回调函数', socketType, callBack)
    this.callBackMapping[socketType] = callBack
  }

  // 注销回调函数
  unregisterCallBack (socketType) {
    this.callBackMapping[socketType] = null
  }

  // 发送数据的方法
  send (data) {
    // 判断socket连接是否成功
    if (this.connected) {
      this.sendRetryCoundt = 0
      this.ws.send(JSON.stringify(data))
    } else {
      this.sendRetryCoundt++
      setTimeout(() => {
        this.send(data)
      }, this.sendRetryCoundt * 500)
    }
  }
}
